63dd20dbd11a7f803b9103ce7a97a88827b611e5,transports/vm/src/main/java/org/mule/transport/vm/VMMessageReceiver.java,VMMessageReceiver,getFirstMessages,#,189
Before Change
// keep batching if more events are available
for (int i = 0; i < batchSize && message != null; i++)
{
message = (MuleEvent)queue.poll(0);
if (message != null)
{
messages.add(new DefaultMuleMessage(message.getMessage(), endpoint.getMuleContext()));
After Change
// keep batching if more events are available
for (int i = 0; i < batchSize && message != null; i++)
{
message = getMessage(queue, 0);
if (message != null)
{
messages.add(new DefaultMuleMessage(message, endpoint.getMuleContext()));